package pers.cz.logtail.queue;

import java.util.List;

/**
 * @program: JefLogTail
 * @descrvate iption: 队列配置
 * @author: Cheng Zhi
 * @create: 2023-03-15 17:46
 **/
public class QueueConf {

    private List<Address> addLists;

    private String addstr;

    /**
     * 队列类型：Kafka，rabbit等
     */
    private QueueEnum QueueType;

    private String keySerializer;
    private String valueSerializer;
    private String acks;
    private String retries;
    private String batchSize;
    private String lingerMs;
    private String bufferMemory;

    public String getAddstr() {
        return addstr;
    }

    public void setAddstr(String addstr) {
        this.addstr = addstr;
    }

    public QueueEnum getQueueType() {
        return QueueType;
    }

    public void setQueueType(QueueEnum queueType) {
        QueueType = queueType;
    }

    public List<Address> getAddLists() {
        return addLists;
    }

    public void setAddLists(List<Address> addLists) {
        this.addLists = addLists;
    }

    public String getKeySerializer() {
        return keySerializer;
    }

    public void setKeySerializer(String keySerializer) {
        this.keySerializer = keySerializer;
    }

    public String getValueSerializer() {
        return valueSerializer;
    }

    public void setValueSerializer(String valueSerializer) {
        this.valueSerializer = valueSerializer;
    }

    public String getAcks() {
        return acks;
    }

    public void setAcks(String acks) {
        this.acks = acks;
    }

    public String getRetries() {
        return retries;
    }

    public void setRetries(String retries) {
        this.retries = retries;
    }

    public String getBatchSize() {
        return batchSize;
    }

    public void setBatchSize(String batchSize) {
        this.batchSize = batchSize;
    }

    public String getLingerMs() {
        return lingerMs;
    }

    public void setLingerMs(String lingerMs) {
        this.lingerMs = lingerMs;
    }

    public String getBufferMemory() {
        return bufferMemory;
    }

    public void setBufferMemory(String bufferMemory) {
        this.bufferMemory = bufferMemory;
    }
}
